package com.shanks.framework.mq.processor;

import com.shanks.framework.mq.domain.MQMessage;


public interface MQProcessor {
    /**
     * 消息处理
     *
     * @param mqMessage
     * @return
     */
    Boolean handleMessage(MQMessage mqMessage) throws Exception;
}
